package chapter04

/**
 * @author: 余辉
 * @blog: https://blog.csdn.net/silentwolfyh
 *        descriptions: 自定义Spark中的RDD，实现RDD中 Transformation 和 action算子
 *        date: 2024 - 09 - 02 11:05 上午
 */
object RDDTest {
  def main(args: Array[String]): Unit = {

    val sc = new Context

    val rdd = sc.textFile("doc/exercise/电影评分/rating.json")

    val res = rdd.map(_.toUpperCase())
      .map("xx - " + _)
      .map(_ ++ " _ ")
    res.foreach(println)
  }
}